package org.halk.kafka_springboot_demo.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.annotation.KafkaListener;

/**
 * @Author halk
 * @Date 2023/5/19 15:04
 */
@Configuration
@Slf4j
public class KafkaConsumer {

    @KafkaListener(topics = "halk")
    public void kafkaConsumer(String msg) {
        log.info("-----------------{}", msg);
    }
}
